package com.apex.spark.stream;

import com.apex.spark.SparkBaseSink;
import com.apex.spark.SparkEnvironment;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;

/**
 * 对上游数据进行实时入库操作
 */
public interface SparkStreamingSink extends SparkBaseSink {
    /**
     *  实时数据输出
     * @param env 执行环境
     * @param inDataSet 上游发来的数据集
     */
    void outputStreaming(SparkEnvironment env, Dataset<Row> inDataSet);
}
